package online.chazi.bootplus.kafka.consumer.handler;

import java.time.Duration;

/**
 * 说明：作者很懒，什么都没留下
 * Created by 叉子同学 on 2020-04-30 23:43
 */
public abstract class SimpleKafkaConsumerHandler<K, V> implements KafkaConsumerHandler<K, V> {

    private final Duration sleep = Duration.ofMillis(500);

    @Override
    public Duration sleep() {
        return sleep;
    }

    @Override
    public void consumeCount(String topic, int partition, int count) {
    }

    @Override
    public void recordsEmpty() {
    }

    @Override
    public void caughtException(Throwable throwable) {
    }

    public Duration getSleep() {
        return sleep;
    }

}
